Add GroupId to queues (tenant/group key with SQS fair-queue, FIFO, and Service Bus session support) - #579

* Round-trip GroupId in Redis queue envelope

Depends on FoundatioFx/Foundatio#579

* Register the empty GroupId queue regression

* Pin guarded build workflow for feature branch validation

* Consume the queue-group-id nightly of Foundatio and Foundatio.TestHarness

The GroupId APIs are not in 13.0.4. Use the nightly until a release is available.

* Count and back off on worker dequeue errors

The Redis worker loop logged dequeue errors and immediately looped again without counting them. It now counts them, ignores cancellation only when its own token is cancelled, and waits one second before retrying. Documents why the delayed-retry GroupId test is skipped: Redis requeues delayed retries in the minute-interval maintenance task.

* Restore main worker loop; keep GroupId plumbing only

* Use matching GroupId core and TestHarness preview

* Accept groupIdResolver in GetQueue, run base resolver tests, use core preview .0.21

* Update Foundatio to 13.0.5-preview.0.10 and point build workflow back to main

* Remove archived Minio provider from README

* Retry test flush after refreshing cluster topology when a cached primary became a replica

* Format

* Round-trip GroupId in Azure Storage queue envelope

Depends on FoundatioFx/Foundatio#579

* Align legacy enqueue event metadata with stored messages

* Pin guarded build workflow for feature branch validation

* Consume the queue-group-id nightly of Foundatio and Foundatio.TestHarness

The GroupId APIs are not in 13.0.4. Use the nightly until a release is available.

* Forward the original body to the dead-letter queue and back off on worker errors

Dead-lettering rebuilt the message from the deserialized value, which a handler may have changed. It now forwards the original body, keeping the payload, GroupId, CorrelationId and properties exactly. The worker loop logs SDK timeouts, waits at least one second after a dequeue error, and does not abandon during shutdown. The metadata test no longer asserts on missing config and deletes the queue it creates. Legacy mode now runs the reused-options test.

* Limit queue changes to GroupId; restore main worker loop and dead-letter envelope

* Use matching GroupId core and TestHarness preview

* Accept groupIdResolver in GetQueue, run base resolver tests (legacy asserts GroupId is not persisted), use core preview .0.21

* Update Foundatio to 13.0.5-preview.0.10 and point build workflow back to main

* Remove archived Minio provider from README

* Include persisted CorrelationId and Properties on the Enqueued entry in Default mode

…y, fast emulator drain (#103)

* Map GroupId to SessionId and preserve retry message fields

Depends on FoundatioFx/Foundatio#579

* Register empty GroupId and isolate session guard tests

* Pin guarded build workflow for feature branch validation

* Stop claiming GroupId affects delivery

Service Bus ignores SessionId unless the queue requires sessions, and this provider cannot receive from session-enabled queues, so GroupId cannot change delivery. Remove SupportsGroupId so the base queue logs that, and add a regression test.

Also consume the queue-group-id nightly of Foundatio and Foundatio.TestHarness until a release is available.

* Schedule the delayed retry before completing the original message

A failed send after completing the original lost the message. The retry is now sent first, and gets a new MessageId when duplicate detection is on so it is not dropped as a duplicate. The worker loop now logs SDK timeouts and waits at least one second after a dequeue error. Adds the delayed-retry GroupId test.

* Limit retry changes to SessionId and send-before-complete; restore main worker loop

* Use matching GroupId core and TestHarness preview

* Add session receive for session-enabled queues; make emulator drain state-driven and settle in-flight entries on delete

Drain peeks the queue instead of sleeping for 5s per call, waits only for a peeked scheduled message's due time (the emulator ignores CancelScheduledMessagesAsync), and DeleteQueueAsync completes messages this instance dequeued but never settled so their locks cannot leak into later tests. Emulator suite: ~19 min with cross-test failures -> 39s green.

* Update Foundatio to 13.0.5-preview.0.10 and point build workflow back to main

* Keep session receiver until settlement succeeds and untrack cancelled session entries

* Address review feedback: pattern matching, shared stats/untrack helpers, drain scan type, worker error backoff, TimeProvider for schedules

* Use pattern matching for failure reason checks

* Harden sessions: keep group order on abandon, validate GroupId before send, release expired unsettled entries, share accept/receive deadline, avoid retry copies with duplicate detection, count copy redeliveries

* Detect duplicate detection on existing queues, compare-and-remove tracked entries, grace period before releasing expired locks, document RetryDelay

* Refresh duplicate-detection state on create and delete, abandon entries that fail to settle during delete, let Enqueuing handlers assign a missing session GroupId

* Include the exception message in unsettled-message log entries

* Add missing blank lines between members

* Add blank line after stale session receiver disposal

* Add SQS GroupId, FIFO and dead-letter fixes

Depends on FoundatioFx/Foundatio#579

* Retain SQS messages on dead-letter lookup failure

* Pin guarded build workflow for feature branch validation

* Keep the SQS worker alive when dequeue or abandon fails

A transient AWS error or AccessDenied during a dead-letter lookup escaped the worker loop and permanently stopped it. Log and count the error, wait one dequeue interval, and keep working; the message becomes visible again after its visibility timeout.

Also consume the queue-group-id nightly of Foundatio and Foundatio.TestHarness until a release is available.

* Validate SQS options again after Enqueuing handlers and back off on worker errors

Handlers can change GroupId, so the SQS limits and the FIFO GroupId requirement are checked again before sending and surface as QueueException/ArgumentException instead of a raw AWS error. The worker loop only treats cancellation as a stop signal when its own token is cancelled, so SDK timeouts are logged and counted, and waits at least one second after a dequeue error so it cannot spin hot.

* Delay worker dequeue errors by DequeueInterval and keep cancellation handling from main

* Use matching GroupId core and TestHarness preview

* Accept groupIdResolver in GetQueue, run base resolver tests, use core preview .0.21

* Allow zero DeliveryDelay on FIFO queues and skip DelaySeconds for FIFO

* Update Foundatio to 13.0.5-preview.0.10 and point build workflow back to main

* Back off at least one second after dequeue errors in the SQS worker

* Address review feedback: DLQ resolution and name validation, SQS id/attribute validation, dequeue error backoff, emulator tests replace synthetic tests; remove archived Minio from README

* Remove unused HttpClientFactory option (only needed by removed synthetic tests); use pattern matching for null/equality checks

* Share queue stats construction and simplify dead-letter move

* Harden SQS dead lettering: use queue only after redrive setup, fall back to created DLQ during policy propagation, DLQ inherits encryption, delete conventional DLQ, clamp retry visibility to 12h, clear queue url on delete

* Resume partial queue setup, reuse existing DLQ with different attributes, limit redrive fallback to propagation window, delete source queue on unused instance, worker re-ensures queue

* Capture DLQ propagation fallback before the policy read, honor content-based deduplication on existing FIFO queues, forget a deleted queue's cached url

* Refresh FIFO content-based deduplication periodically and retry once with a generated id if SQS rejects a send after it is turned off

* Read content-based deduplication on the first implicit-id send of a created queue and forget the queue url when the refresh finds it deleted

* Add missing blank lines between members

* Add blank lines after braceless if bodies in tests

* Inline the dequeue error backoff delay instead of adding a SafeDelay extension

* Share the CorrelationId attribute name constant and assert group id is not exposed as a property

* Apply suggestion from @niemyjski

* Extract FIFO deduplication into a helper, tolerate a failed dedup refresh, log queue deletes, and restore the attribute TODO and deadRequest

* Resolve ContentBasedDeduplication once instead of polling, require the propagation fallback with caller-read attributes, warn when an exhausted message is discarded, and move new private helpers to the bottom

* Settle ContentBasedDeduplication from the next send when it can't be read, and forget a deleted queue's url on stats and the dedup retry

* Simplify the CorrelationId property check and fix the delivery-delay test race with the long poll

* Only delete a dead letter queue the source policy confirms, mark setup pending before creating the source, forget a deleted queue on redrive lookup, and drop GroupId from trace logs

* Update Microsoft.NET.Test.Sdk, xunit.v3.mtp-v2, and xunit.runner.visualstudio package versions

* Revalidate resolved dead letter ownership on delete and tolerate missing attribute access

Only a dead letter queue this instance created is deleted without checking the source's current redrive policy; one resolved from the policy is re-read before deletion. A failed policy read (e.g. AccessDenied) now skips dead letter cleanup instead of blocking deletion of the source queue.

* Upgraded Foundatio to 13.0.5-preview.0.16

* Keep a confirmed dead letter queue url so a retried delete still removes it